package com.jmd.rx.client;

import com.jmd.rx.TOPIC;
import io.reactivex.rxjava3.subjects.PublishSubject;

public interface InnerMqClient {

    String getId();

    <T> PublishSubject<Object> sub(TOPIC topic, SubscribeCallback<T> callback);

    <T> void pub(TOPIC topic, T msg);

    void destroy();

}
